package cn.boat.router.consumer;

import java.util.List;

public interface ConsumerWatcherInterface {
    void watchConsumerId(String consumerGroupId, String consumerId) throws Exception;
    void watchIntrestingTopicsBrokerLeaderChange(String consumerGroupId, String consumerId, List<String> topicsList) throws Exception;
    void watchIntrestingTopicsBrokerLeaderChange(String consumerGroupId, String consumerId, String topic) throws Exception;
}